package com.zx.mes.disruptor.hyl.quickstart;


import com.lmax.disruptor.EventHandler;
import lombok.extern.java.Log;

/**
 * event handler
 * @author huayunlong
 * @date 2018-9-5
 */
@Log
public class OrderEventHandler implements EventHandler<OrderEvent>{
    @Override
    public void onEvent(OrderEvent event, long sequence, boolean endOfBatch) throws Exception {
        log.info("消费端:"+event.getValue()+"  sequence:"+sequence+" endOfBatch:"+endOfBatch);
    }
}
